package cn.iocoder.yudao.module.erp.service.customeraccount;
import cn.iocoder.yudao.module.erp.dal.dataobject.customeraccount.CustomerAccountDO;
import cn.iocoder.yudao.module.erp.dal.mysql.customeraccount.CustomerAccountMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
/*@Service*/
public class CustomerAccountFinishService {

    // 使用 ConcurrentHashMap 存储数据
    private ConcurrentHashMap<String, CustomerAccountDO> dataMap = new ConcurrentHashMap<>();

    @Resource
    private CustomerAccountMapper customerAccountMapper;

    // 从数据库加载数据到 ConcurrentHashMap
    public void loadDataFromDB(CustomerAccountDO customerAccountDO) {
        dataMap.put(UUID.randomUUID().toString().replace("-", ""), customerAccountDO);
    }

    // 将 ConcurrentHashMap 中的数据同步到数据库
    public void syncDataToDB() {
        /*dataMap.forEach((key, value) -> {
            // 假设这里使用 JPA 更新数据库中的数据
            // 例如，更新一个名为 DataEntity 的实体类中的数据
            // DataEntity entity = entityManager.find(DataEntity.class, key);
            // entity.setValue(value);
            // entityManager.merge(entity);
            // 这里简化为打印操作
            System.out.println("Syncing data: " + key + " -> " + value);
        });*/
    }

    // 更新 ConcurrentHashMap 中的数据
   /* public void updateDataInMap(String key, int value) {
        dataMap.put(key, value);
    }*/
}


